package com.mo.axion.stream.callback;

import io.lettuce.core.RedisFuture;
import io.lettuce.core.api.async.RedisAsyncCommands;

import java.util.List;

/**
 * @author Mo
 * @createTime 2024/4/13 20:12
 * @description redis pipeline接口定义
 */
public interface RedisPipelineCallBack {
    /**
     * 具体执行逻辑
     * @param redisAsyncCommands
     * @return
     */
    List<RedisFuture<?>> invoke(RedisAsyncCommands redisAsyncCommands);
}
